import threading
import Queue
import time

def worker(num, result_queue):
    # 这个线程会一直执行这个函数
    print("线程", threading.current_thread().name, "开始执行")
    for i in range(num):
        print("线程", threading.current_thread().name, "执行了", i)
        # 将结果放入队列中
        result_queue.put(i * 2)

    # 将结果从队列中取出并存储到变量中
    result = result_queue.get()
    print("线程", threading.current_thread().name, "结束执行")
    return result

if __name__ == '__main__':
    # 创建一个队列用于传递参数
    result_queue = Queue()

    # 创建两个线程
    t1 = threading.Thread(target=worker, args=(5, result_queue))
    t2 = threading.Thread(target=worker, args=(10, result_queue))

    # 启动线程
    t1.start()
    t2.start()

    # 等待线程结束
    t1.join()
    t2.join()

    	

    # 从队列中取出结果并存储到变量中
    result = result_queue.get()

    # 输出结果
    print("所有线程结束执行，结果为：", result)
